package com.bigdata.topN

import org.apache.spark.sql.SparkSession

object Test {
  def main(args: Array[String]): Unit = {
    val session = SparkSession.builder().appName("articleTopN").master("local").getOrCreate()
    val dataFrame = session.sqlContext.read.load("hdfs://localhost:9000/bigdata/2019-06-28-support")
    dataFrame.show()
  }

}
